package org.ccay.async.conduit;

import org.ccay.async.AsyncMessage;

/**
 * 异步通道
 * 	
 */
public interface AsyncConduit {
	
	/**
	 * 是否能处理指定的消息。
	 * 
	 * 
	 * @since Dec 7, 2011
	 * @param message
	 * @return
	 */
	public boolean accept(AsyncMessage message);
	
	/**
	 * 处理消息
	 * 	
	 * 
	 * @since Dec 6, 2011
	 * @param message	待处理的消息
	 */
	public void handle(AsyncMessage message);

}
